f1f1300089e2f2368d33e9ec6e16495156b2b37a,advanced/src/main/java/org/neo4j/onlinebackup/ha/AbstractSlave.java,AbstractSlave,reconnectToMaster,#,87
Before Change
public boolean reconnectToMaster()
{
masterConnection = new Connection( masterIp, masterPort );
while ( !masterConnection.connected() )
{
if ( masterConnection.connectionRefused() )
{
return false;
}
}
jobEater.addJob( new ConnectToMasterJob( masterConnection, this ) );
return true;
}
After Change
public boolean reconnectToMaster()
{
for ( int i = 0; i < masterConnections.length; i++ )
{
if ( masterConnections[i].connected() )
{
continue;
}
masterConnections[i] = new Connection( masterIp, masterPort );
while ( !masterConnections[i].connected() )
{
if ( masterConnections[i].connectionRefused() )
{
return false;
}
}
if ( masterConnections[i].connected() )
{
String name = "nioneodb";
if ( i == 1 )
{
name = "lucene";
}
else if ( i == 2 )
{
name = "lucene-fulltext";
}
jobEater.addJob( new ConnectToMasterJob( masterConnections[i],
this, name, xaDataSources[i] ) );
}
}
return true;